package com.wuercloud.mq.message.consumer;

import com.wuercloud.mq.common.ResultRes;

/**
 * Created by JiangWL on 2017/3/30.
 */
public interface ConsumerObserver {
    /**
     * 实现类时需注入自身的bizQueue属性
     * @return
     */
    String getBizQueue();
    /**
     * 业务处理时理时实现消费方法
     * @param bizQueue  业务队列名称或routingKey
     * @param message  待处理的信息
     * @return
     */
    ResultRes consume(String bizQueue, String message);
}
